package com.lubase.wfengine.remote.impl;

import lombok.Getter;
import lombok.Setter;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Service;

import java.util.concurrent.ConcurrentLinkedQueue;

/**
 * 流程引擎 内存队列服务
 */
@Setter
@Getter
@Service
@ConditionalOnProperty(name = "lubase.wf-engine.mq-type", havingValue = "memory")
public class WFEngineMemoryMQService {
    /**
     * 引擎事件队列
     */
    ConcurrentLinkedQueue<String> engineQueue = new ConcurrentLinkedQueue<>();
    /**
     * 更新表事件队列
     */
    ConcurrentLinkedQueue<String> updateTableQueue = new ConcurrentLinkedQueue<>();
    /**
     * 公开事件流程事件队列
     */
    ConcurrentLinkedQueue<String> openEventQueue = new ConcurrentLinkedQueue<>();
}
